package com.shopRedis;

import com.shopRedis.properties.RedisProperties;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.HashSet;
import java.util.Set;

//@Configuration
//public class JedisClusterConfig {
//
//    @Autowired
//    private RedisProperties redisProperties;
//
//    /**
//     * 注意：
//     * 这里返回的JedisCluster是单例的，并且可以直接注入到其他类中去使用
//     *
//     * @return
//     */
////    @Bean
////    public JedisCluster getJedisCluster() {
////        String[] serverArray = redisProperties.getClusterNodes().split(",");//获取服务器数组(这里要相信自己的输入，所以没有考虑空指针问题)
////        Set<HostAndPort> nodes = new HashSet<HostAndPort>();
////
////        for (String ipPort : serverArray) {
////            String[] ipPortPair = ipPort.split(":");
////            nodes.add(new HostAndPort(ipPortPair[0].trim(), Integer.valueOf(ipPortPair[1].trim())));
////        }
////
////        return new JedisCluster(nodes, redisProperties.getCommandTimeout(), 1000, 1, new GenericObjectPoolConfig());//需要密码连接的创建对象方式
////    }
//}